package com.cn.daimajiangxin.flink.transformation;

import java.io.Serializable;
import java.util.Date;
// 日志实体类
public class LogEntry implements Serializable {
    private static final long serialVersionUID = 1L;
    private Date timestamp;
    private String logLevel;
    private String message;

    public LogEntry(Date timestamp, String logLevel, String message) {
        this.timestamp = timestamp;
        this.logLevel = logLevel;
        this.message = message;
    }

    public Date getTimestamp() {
        return timestamp;
    }

    public String getLogLevel() {
        return logLevel;
    }

    public String getMessage() {
        return message;
    }

    @Override
    public String toString() {
        return "LogEntry{" +
                "timestamp=" + timestamp +
                ", logLevel='" + logLevel + '\'' +
                ", message='" + message + '\'' +
                '}';
    }
}

